Node / meshtastic / Meshtastic-Android / files / core / database / src / commonMain / kotlin / org / meshtastic / core / database / dao / MeshLogDao.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.database.dao

Tff7b72import T7ee787androidx.room3.Dao

Tff7b72import T7ee787androidx.room3.Insert

Tff7b72import T7ee787androidx.room3.OnConflictStrategy

Tff7b72import T7ee787androidx.room3.Query

Tff7b72import T7ee787androidx.room3.Transaction

Tff7b72import T7ee787kotlinx.coroutines.flow.Flow

Tff7b72import T7ee787org.meshtastic.core.database.DatabaseConstants.SQLITE_MAX_BIND_PARAMETERS

Tff7b72import T7ee787org.meshtastic.core.database.entity.MeshLog

Tf0883e@Dao

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4)

Tff7b72interface T56d364MeshLogDao Tb4b4b4{

Tff7b72companion Tff7b72object Tb4b4b4{

T8b949e/** Shared SQL for querying logs by from_num and port_num, used by both Flow and snapshot variants. */

Tff7b72private Tff7b72const Tff7b72val Te6edf3LOGS_FROM_QUERY Tff7b72=

Ta5d6ff"""

Ta5d6ff SELECT * FROM log

WHERE from_num = :fromNum AND (:portNum = -1 OR port_num = :portNum)

ORDER BY received_date DESC LIMIT :maxItem

Ta5d6ff"""

Tb4b4b4}

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffSELECT * FROM log ORDER BY received_date DESC LIMIT :maxItemTa5d6ff"Tb4b4b4)

Tff7b72fun Td2a8ffgetAllLogsTb4b4b4(Te6edf3maxItemTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72>

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffSELECT * FROM log ORDER BY received_date ASC LIMIT :maxItemTa5d6ff"Tb4b4b4)

Tff7b72fun Td2a8ffgetAllLogsInReceiveOrderTb4b4b4(Te6edf3maxItemTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72>

T8b949e/**

* Retrieves [MeshLog]s matching 'from_num' (nodeNum) and 'port_num' (PortNum).

*

* @param portNum If -1, returns all logs regardless of port. If 0, returns logs with port 0.

*/

Tf0883e@QueryTb4b4b4(Te6edf3LOGS_FROM_QUERYTb4b4b4)

Tff7b72fun Td2a8ffgetLogsFromTb4b4b4(Te6edf3fromNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3portNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3maxItemTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tff7b72>

Tf0883e@Insert Tff7b72suspend Tff7b72fun Td2a8ffinsertTb4b4b4(Te6edf3logTb4b4b4: Te6edf3MeshLogTb4b4b4)

T8b949e/**

* Snapshot + IGNORE-insert used by DatabaseMerger to carry telemetry/position/traceroute history across transports.

* uuid is a unique string per row, so IGNORE is just belt-and-suspenders against a rare clash.

*/

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffSELECT * FROM logTa5d6ff"Tb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffgetAllLogsSnapshotTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>

Tf0883e@InsertTb4b4b4(Te6edf3onConflict Tff7b72= Te6edf3OnConflictStrategyTb4b4b4.Te6edf3IGNORETb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffinsertIgnoreTb4b4b4(Te6edf3logsTb4b4b4: Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>Tb4b4b4)

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffDELETE FROM logTa5d6ff"Tb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffdeleteAllTb4b4b4(Tb4b4b4)

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffDELETE FROM log WHERE uuid = :uuidTa5d6ff"Tb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffdeleteLogTb4b4b4(Te6edf3uuidTb4b4b4: Tffa657StringTb4b4b4)

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffDELETE FROM log WHERE uuid IN (:uuids)Ta5d6ff"Tb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffdeleteLogsByUuidTb4b4b4(Te6edf3uuidsTb4b4b4: Te6edf3ListTff7b72<Tffa657StringTff7b72>Tb4b4b4)

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffDELETE FROM log WHERE from_num = :fromNum AND port_num = :portNumTa5d6ff"Tb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffdeleteLogsTb4b4b4(Te6edf3fromNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3portNumTb4b4b4: Tffa657IntTb4b4b4)

Tf0883e@QueryTb4b4b4(Ta5d6ff"Ta5d6ffDELETE FROM log WHERE received_date < :cutoffTimestampTa5d6ff"Tb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffdeleteOlderThanTb4b4b4(Te6edf3cutoffTimestampTb4b4b4: Tffa657LongTb4b4b4)

T8b949e/**

* Suspend snapshot variant of [getLogsFrom] for one-shot reads (no Flow observer overhead). Used when a caller

* needs to read-then-process-then-delete in two steps — the selection requires Kotlin parsing so it stays outside

* the delete transaction, but the delete itself is atomic (see [deleteLogsByUuidAtomic]).

*/

Tf0883e@QueryTb4b4b4(Te6edf3LOGS_FROM_QUERYTb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffgetLogsSnapshotTb4b4b4(Te6edf3fromNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3portNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3maxItemTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>

T8b949e/**

* Returns one deterministic keyset page for bounded snapshot processing. [beforeReceivedDate] and [beforeUuid]

* identify the last row of the previous page; null values start from the newest row.

*/

Tf0883e@QueryTb4b4b4(

Ta5d6ff"""

Ta5d6ff SELECT * FROM log

WHERE from_num = :fromNum

AND (:portNum = -1 OR port_num = :portNum)

AND (

:beforeReceivedDate IS NULL

OR received_date < :beforeReceivedDate

OR (received_date = :beforeReceivedDate AND uuid < :beforeUuid)

)

ORDER BY received_date DESC, uuid DESC

LIMIT :pageSize

Ta5d6ff"""Tb4b4b4,

Tb4b4b4)

Tff7b72suspend Tff7b72fun Td2a8ffgetLogsSnapshotPageTb4b4b4(

Te6edf3fromNumTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3portNumTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3beforeReceivedDateTb4b4b4: Tffa657Long?Tb4b4b4,

Te6edf3beforeUuidTb4b4b4: Tffa657String?Tb4b4b4,

Te6edf3pageSizeTb4b4b4: Tffa657IntTb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3MeshLogTff7b72>

T8b949e/**

* Atomically deletes all logs matching [uuids], chunking internally to stay under SQLite's bind-parameter limit.

* The entire batch is all-or-nothing: a failure rolls back every chunk.

*/

Tf0883e@Transaction

Tff7b72suspend Tff7b72fun Td2a8ffdeleteLogsByUuidAtomicTb4b4b4(Te6edf3uuidsTb4b4b4: Te6edf3ListTff7b72<Tffa657StringTff7b72>Tb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3uuidsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tff7b72return

Tff7b72for Tb4b4b4(Te6edf3chunk Tff7b72in Te6edf3uuidsTb4b4b4.Te6edf3chunkedTb4b4b4(Te6edf3SQLITE_MAX_BIND_PARAMETERSTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3deleteLogsByUuidTb4b4b4(Te6edf3chunkTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}